[AID-BACKEND-012] Создать Метод ProcessVoiceStream() в grpc-analytics
Реализация асинхронного хендлера Speech-to-Text транскрибации
NoteКраткая карточка задачи
- Репозиторий / Компонент:
grpc-analytics(Домен AID). - Контракт метода: Kafka Consumer Handler
ProcessVoiceStream(). - Статус: Готово к реализации
- Ссылка на Метод: Спецификация ИИ-фильтрации обсценного контента
- Инструкция по шагам:
- На Шаге 4: Настроить вычитку сообщений из топика
bpds.inventory.in.voice.stream. Извлечьaudio_file_url,app_langиx_request_id. - На Шаге 5: Использовать
audio_file_urlдля скачивания бинарного файла изMinIOв оперативную память воркера. - Передать байты во встроенную модель
Whisper Tiny. Выполнить инференс и получить сырую нефильтрованную строку распознанного текста. - На Шаге 6: Запаковать полученную строку в структуру общего текстового топика (
raw_text_input,app_lang,x_request_id, а также выставить флаг источника"source": "WHISPER_STT") и опубликовать в топикbpds.inventory.in.receipt.upload.
- На Шаге 4: Настроить вычитку сообщений из топика